from datetime import time
from multiprocessing.pool import Pool


def func(param):
    for i in range(3):
        print('test',i,param)
        time.sleep(1)
        #为什么只运行一个循环？

if __name__ == '__main__':
    # 1.实例化进程池（池中有两个进程）
    pool = Pool(2)
    # 2.告诉进程池要执行的目标函数
    for i in range(10):
        pool.apply_async(
            func=func,      # 指定目标函数
            args=(i,)       # 传递参数
        )
    # 3.关闭进程池
    pool.close()
    # 4.堵塞主进程
    pool.join()